package Transforming_Observables

import (
	"context"
	"fmt"
	"github.com/reactivex/rxgo/v2"
)

// 通过一个转化函数进行转化之后再发布
func Demo_Map() {
	fmt.Println("Demo_BufferWithCount###########################")
	observable := rxgo.Just(1, 2, 3)().
		Map(func(_ context.Context, i interface{}) (interface{}, error) {
			return i.(int) * 10, nil
		})

	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅：", item.E)
		}
		fmt.Println("订阅：", item.V)
	}

}
